package utils;

/**
 * Create by zhh on 2022/9/9.
 * 修改要Sink的数据库的表名和列名
 */
public class MySqlTableUtils {
    public static String table_name="kafka_wc";
    public static String col_1 = "word";
    public static String col_2 = "count";
    public static String col_3 = "user_category";
    public static String col_4 = "user_number";
}
